package com.wm.wmim.connect.ws.rpc.impl;

import com.wm.wmim.common.dto.RpcRespDTO;
import com.wm.wmim.connect.sdk.push.bo.req.PushWsMessageReqBO;
import com.wm.wmim.connect.sdk.push.bo.resp.PushWsMessageRespBO;
import com.wm.wmim.connect.ws.api.rpc.PushWsMessageRpcService;
import com.wm.wmim.connect.ws.service.PushMessageService;
import org.apache.dubbo.config.annotation.DubboService;

import javax.annotation.Resource;

/**
 * @author weiming
 * @date 2024/10/19 14:08
 * @description
 */
@DubboService(version = "1.0.0")
public class PushWsMessageRpcImpl implements PushWsMessageRpcService {

    @Resource
    private PushMessageService pushMessageService;

    @Override
    public RpcRespDTO<PushWsMessageRespBO> pushMessageLocal(PushWsMessageReqBO reqBO) {

        PushWsMessageRespBO aBoolean = pushMessageService.pushMessageLocal(reqBO);
        return RpcRespDTO.buildSuccess(aBoolean);
    }

}
